package com.axxc.jpa.task.rabbitmsg.receiver;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 
 * @ClassName RabbitMqTopicExchangeMsgReceiver
 * @Description 消费路由key为topic.message队列中的消息
 * @author xxc
 * @data 2018年8月6日14:41:46
 * @see com.axxc.jpa.config.RabbitMqConfig
 */
@Component
@RabbitListener(queues = "fanout.C")
public class RabbitMqFanoutExchangeMsgReceiverC {

	private Logger logger = LoggerFactory.getLogger(getClass());

	@RabbitHandler
	public void processA(String msg) {
		//所有接收者都接受到了消息
		logger.info("fanoutExchangeReceiverC  -消费者 : {}", msg);
	}
}
